package yecq_test1;

import java.util.concurrent.Semaphore;


public class main_PC {

        // 设置统一的信号量
        static char count = 'G';
        // 设置同时只有四个线程可访问该信号量下的程序段内容
        final static Semaphore notFull = new Semaphore(4);
        //  设置0表示实现这个锁的模块先跳过，运行其他程序
        final static Semaphore notEmpty = new Semaphore(0);
        // 设置同时只有1个线程可访问该信号量下的程序段内容，防止内容更新不同时
        final static Semaphore mutex = new Semaphore(1);


        public static void main(String[] args) throws Exception {

            // 产生线程完成生产者和消费者的运行调用
            new Thread(new Producer()).start();
            new Thread(new Customer()).start();
            new Thread(new Producer()).start();
            new Thread(new Customer()).start();
            new Thread(new Producer()).start();
            new Thread(new Customer()).start();

        }
}
